#!/bin/bash
# 创建 源表 数组
arr=(ACCOUNT_MASTER ALERT CUSTOMER_MASTER MONITORING_RULE SCREENING_RESULT SUSPICIOUS_TXN_REPORT TRANSACTION_DETAIL UBO_INFO WATCHLIST_DETAIL WATCHLIST_MASTER)
for i in "${arr[@]}"        # for循环遍历数组
do
    echo "开始导入表: AML_$i -> ODS_$i, 分区: $ETL_DATE" # 数据导入声明
        # 用sqoop将oracle中的 源表 数据导入到hive的 目标表 中。
        # 使用hcatalog，让sqoop通过hcatalog自动处理hive目标表的文件格式为ORC格式
    sqoop import \  #用sqoop导入
        --connect jdbc:oracle:thin:@192.168.4.120:1521:orcl \ #连接oracle
        --username FXQ \  #输入用户名
        --password 123456 \   #输入密码
        --table "AML_$i" \   #源表
        --hcatalog-database ods \  #指定Hive数据库
        --hcatalog-table "ODS_$i" \  #目标表
        --hive-partition-key etl_date \  #Hive分区字段
        --hive-partition-value "2025-10-15" \  #分区值
        -m 1

    # 查询单次命令执行结果
    if [ $? -eq 0 ]; then
        echo "表 AML_$i 导入成功"
    else
        echo "表 AML_$i 导入失败"
    fi
done
echo "表导入脚本执行完成"